package com.yuke.cloud.common.base.constant;
/**
 * <p><b>Description:</b> 常量类，用于rabbitmq相关的消息常量配置 <p>
 * <b>Company:</b> 
 *
 */
public class MQConstants {
	
	/**业务交换机名称*/
	public static final String BUSINESS_EXCHANGE = "yuke.business.exchange";  //可根据消费者业务模块设置或统一设置
	/**业务队列名称*/
	public static final String BUSINESS_QUEUE = "yuke.business.queue";  //可根据不同的具体消费者业务模块进行设置
	/**业务key*/
	public static final String BUSINESS_KEY = "yuke.business.key";  //可根据不同的具体的消费者业务模块进行设置

	public static final String BUSINESS_QUEUE_OPC = "yuke.business.queue.opc";  //OPC模块消费的消息队列
	public static final String BUSINESS_KEY_OPC = "yuke.business.key.opc";
	public static final String BUSINESS_QUEUE_TMC = "yuke.business.queue.tmc";  //WMC模块消费的消息队列
	public static final String BUSINESS_KEY_TMC = "yuke.business.key.tmc";
	public static final String BUSINESS_QUEUE_WMC = "yuke.business.queue.wmc";  //WMC模块消费的消息队列
	public static final String BUSINESS_KEY_WMC = "yuke.business.key.wmc";

	/**具体业务的消息类型*/
	public static final String MQ_OPC_SEND_EMAIL = "SEND_EMAIL";  //发送email业务
	public static final String MQ_OPC_SEND_SMS = "SEND_SMS";  //发送sms业务
	public static final String MQ_OPC_SEND_NOTIFY = "SEND_NOTIFY";  //发送notify业务
	
	public static final String MQ_PRODUCER_RETRY_KEY = "mq.producer.retry.key";
	public static final String MQ_CONSUMER_RETRY_COUNT_KEY = "mq.consumer.retry.count.key";
	/**死信队列配置*/
	public static final String DLX_EXCHANGE = "yuke.dlx.exchange";
	public static final String DLX_QUEUE = "yuke.dlx.queue";
	public static final String DLX_ROUTING_KEY = "yuke.dlx.routing.key";
	/**发送端重试乘数(ms)*/
	public static final int MUTIPLIER_TIME = 500;
	/** 发送端最大重试时时间（s）*/
	public static final int MAX_RETRY_TIME = 10;
	/** 消费端最大重试次数 */
	public static final int MAX_CONSUMER_COUNT = 5; 
	/** 递增时的基本常量 */
	public static final int BASE_NUM = 2;
	/** 空的字符串 */
	public static final String BLANK_STR = "";
	
	

}
